package com.biao.threadPool;

/**
 * @description: 测试手写的线程池
 * @author:chenwenbiao
 * @createTime:2020/1/17 10:33
 * @Version：1.0
 **/
public class MyFixedSizeThreadPoolWithShutDownTest {

    /**
     * 要执行的代码块，就是任务
     */
    public static class MyTask implements Runnable{
        @Override
        public void run() {
            System.out.println("线程：" + Thread.currentThread().getName() + "，加入线程池后，正在干活。。。。");
        }
    }

    public static void main(String[] args) {
        int taskSize = 60;
        int poolSize = 6;
        MyFixedSizeThreadPoolWithShutDown pool = new MyFixedSizeThreadPoolWithShutDown(taskSize, poolSize);
        for(int i = 0 ; i < taskSize ; i++){
            //将要执行的代码块交出来给到线程池进行调度就可以
            pool.submit(new MyTask());
        }

        // 就是多了一个shutdown方法
        pool.shutDown();
    }
}
